package conlon.rocketmq.service;

import com.baomidou.mybatisplus.extension.service.IService;
import conlon.rocketmq.entity.I8tLocalTransactionEntity;
import org.apache.rocketmq.common.message.Message;

/**
 * <p>
 * 服务类
 * </p>
 *
 * @author conlon
 * @since 2021-08-20
 */
public interface I8tLocalTransactionService extends IService<I8tLocalTransactionEntity> {


    /**
     * 方法描述 记录本地事务
     * @param message 事务消息
     * @return boolean
     * @author conlon
     * @date 2021/8/20
     */
    boolean createI8tTransaction(Message message);

    /**
     * 方法描述 获取消息在表中的唯一key
     * @param transactionId 消息唯一id
     * @return boolean
     * @author conlon
     * @date 2021/8/20
     */
    boolean getUniqKey(String transactionId);
}
